package com.kingsoft.dc.khaos.module.spark.source

import com.kingsoft.dc.khaos.KhaosContext
import com.kingsoft.dc.khaos.metadata.Dependency

trait SourceStrategy {

  type MapSet = Map[String, String]
  /** 数据抽取 */
  def source(kc: KhaosContext,
             module_id: String,
             config: String,
             dependence: Dependency): Any = {}

  /** 获取上游的Schema */
  def schema(dc: KhaosContext,
             config: String,
             dependence: Dependency): Any = {}
}
